//package com.rp.article.stream;
//
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.messaging.Message;
//import org.springframework.messaging.support.MessageBuilder;
//import org.springframework.stereotype.Component;
//
//import java.awt.*;
//
//@Component
//@EnableBinding(MyStreamChannel.class)
//public class StreamServiceImpl implements StreamService{
//
//    @Autowired
//    private MyStreamChannel myStreamChannel;
//
//    @Override
//    public void sendMsg() {
//        Message<String> msg = MessageBuilder.withPayload("这是一个测试").build();
//        myStreamChannel.output().send(msg);
//    }
//}
